// 封装数据库操作

const {config} = require('./db.config');
const mysql = require('mysql');

const pool = mysql.createPool(config);

// 封装sql语句
exports.query = (sql,params) =>{
  return new Promise((resolve,reject) =>{
    // 连接池进行连接
    pool.getConnection((err,conn)=>{
      if(err) {
        reject(err)
        return
      }
      conn.query(sql,params,(err,rows) =>{
        if(err) throw err;
        resolve(rows);
      })
      // 获取连接之后,自动关闭
      conn.release()
    })
  })
}